package DianShang_2024.ds_01.extract

import org.apache.spark.sql.SparkSession

import java.util.Properties

object test02 {
  def main(args: Array[String]): Unit = {
    //  准备sparksql的环境
    val spark=SparkSession.builder()
      .master("local[*]")
      .appName("测试拿到mysql的数据")
      .enableHiveSupport()
      .getOrCreate()

    //  定义Properties对象，以键值对的形式存储连接mysql的配置
    val jdbc_conf=new Properties()
    jdbc_conf.setProperty("user","root")
    jdbc_conf.setProperty("password","123456")
    jdbc_conf.setProperty("driver","com.mysql.jdbc.Driver")

    //  读取mysql的数据并且创建临时表
    spark.read.jdbc("jdbc:mysql://192.168.40.110:3306/shtd_store?useSSL=false","user_info",jdbc_conf)
      .createOrReplaceTempView("mysql_data")
   // 检查能否拿到数据
    spark.sql("select * from mysql_data limit 10").show


  //  关闭环境
    spark.close()
  }

}
